package com.kyrie.dto;

import lombok.Data;

import javax.validation.constraints.NotBlank;
import java.io.Serializable;

/***
 * 描述: kafka消息发布dto
 *
 * @author wuxiang
 * @date 2020-04-23 17:21
 */
@Data
public class KafkaProducerDto implements Serializable {

    private static final long serialVersionUID = 8663656109959279829L;
    @NotBlank(message = "topic不能为空！")
    private String topic;

    private Boolean autoFlush;

    private Object pushContent;


}
